package org.example.operator.action

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

import scala.collection.mutable

/**
 *  案例实操
 *
 */
object Spark05_RDD_Operator_Save {
  def main(args: Array[String]): Unit = {

    val conf: SparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
    val context = new SparkContext(conf)

    val wordRdd= context.makeRDD(List(("a",1),("b",1),("a",2)),2)

  // 行动算子

    wordRdd.saveAsTextFile("output")
    // 对象序列化保存方式
    wordRdd.saveAsObjectFile("output")
    // 必须是键值类型，才可以使用
    wordRdd.saveAsSequenceFile("output")


    context.stop()
  }
}
